package com.example.springcloud.stream.producer.my;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.cloud.stream.messaging.Source;

/**
 * 自定义一个类似于 {@Link Source} 类。
 *
 *  因为在实际中，要往多个topics消息通道发送数据，不可能通道都叫 "input" "output"。
 *
 *  所以需要自定义一个 类似 Source 的类。
 *
 *  定义完后：
 *   spring:
 *      cloud:
 *     stream:
 *       kafka:
 *         binder:
 *           brockers: localhost:9092 #指定kafka的位置
 *           zk-nodes: localhost:2181 #指定zk的位置
 *           auto-create-topics: true #设置为自动创topics，不然会出现topics没有创建，就进行了调用
 *       bindings:
 *           myOuput: # 生产者 实际对应 @Output("myOuput") 中的myOuput字样
 *             destination: stream-dome #把生产的消息放入哪个topics里面
 *             content-type: text/plain #消息类型，就是发送的消息的格式
 *
 *
 * weiximei on 2018/8/25
 *
 */
public interface MySource {

    String OUTPUT = "myOuput";

    @Output(MySource.OUTPUT)
    MessageChannel myOuput();

}
